Embabel Agent Documentation/com.embabel.agent.api.event

Package-level declarations

Types

AbstractAgentProcessEvent

abstract class AbstractAgentProcessEvent(val agentProcess: AgentProcess) : AgentProcessEvent

Convenient superclass for AgentProcessEvent implementations

ActionExecutionResultEvent

class ActionExecutionResultEvent : AbstractAgentProcessEvent

ActionExecutionStartEvent

class ActionExecutionStartEvent(val agentProcess: AgentProcess, val action: Action) : AbstractAgentProcessEvent

AgentDeploymentEvent

data class AgentDeploymentEvent(val agentPlatform: AgentPlatform, val agent: Agent) : AgentPlatformEvent

AgenticEvent

sealed interface AgenticEvent

Root of event hierarchy Any event relating to an agent platform

AgenticEventListener

interface AgenticEventListener

Listen to events related to processes and the platform itself. Subclasses can implement this interface to handle specific events. Default implementations do nothing.

AgentPlatformEvent

interface AgentPlatformEvent : AgenticEvent

System event such as deployment

AgentProcessCompletedEvent

class AgentProcessCompletedEvent(val agentProcess: AgentProcess) : AgentProcessFinishedEvent

AgentProcessCreationEvent

class AgentProcessCreationEvent(val agentProcess: AgentProcess) : AbstractAgentProcessEvent

AgentProcessEmbeddingEvent

class AgentProcessEmbeddingEvent(val agentProcess: AgentProcess, val embeddingEvent: EmbeddingEvent) : AbstractAgentProcessEvent

Re-dispatches an EmbeddingEvent on the AgenticEventListener.onProcessEvent channel when an AgentProcess is active.

AgentProcessEvent

interface AgentProcessEvent : AgenticEvent, InProcess

Event relating to a specific process. Most events are related to a process.

AgentProcessFailedEvent

class AgentProcessFailedEvent(val agentProcess: AgentProcess) : AgentProcessFinishedEvent

AgentProcessFinishedEvent

sealed class AgentProcessFinishedEvent : AbstractAgentProcessEvent

The agent process has finished. It may have completed successfully or failed. Check the status code to determine the outcome.

AgentProcessPausedEvent

class AgentProcessPausedEvent(val agentProcess: AgentProcess) : AbstractAgentProcessEvent

AgentProcessPlanFormulatedEvent

class AgentProcessPlanFormulatedEvent(val agentProcess: AgentProcess, val worldState: WorldState, val plan: Plan) : AbstractAgentProcessEvent

AgentProcessReadyToPlanEvent

class AgentProcessReadyToPlanEvent(val agentProcess: AgentProcess, val worldState: WorldState) : AbstractAgentProcessEvent

AgentProcessStuckEvent

class AgentProcessStuckEvent(val agentProcess: AgentProcess) : AbstractAgentProcessEvent

The AgentProcess is unable to plan from its present state.

AgentProcessWaitingEvent

class AgentProcessWaitingEvent(val agentProcess: AgentProcess) : AbstractAgentProcessEvent

DynamicAgentCreationEvent

data class DynamicAgentCreationEvent(val agentPlatform: AgentPlatform, val agent: Agent, val basis: Any, val timestamp: Instant = Instant.now()) : AgentPlatformEvent

Emitted when we've created an agent for a specific task

EmbeddingEvent

interface EmbeddingEvent

Events emitted by an embedding service call.

EmbeddingEventListener

fun interface EmbeddingEventListener

Listens to EmbeddingEvents.

EmbeddingInvocationEvent

class EmbeddingInvocationEvent(val agentProcess: AgentProcess, val invocation: EmbeddingInvocation, val interactionId: String) : AbstractAgentProcessEvent

Emitted once per embedding call.

EmbeddingRequestEvent

class EmbeddingRequestEvent(val embeddingMetadata: <Error class: unknown class>, val inputs: List<String>, val id: String, val timestamp: Instant = Instant.now()) : EmbeddingEvent

Emitted before an embedding service call.

EmbeddingResponseEvent

class EmbeddingResponseEvent(val request: EmbeddingRequestEvent, val usage: Usage, val runningTime: Duration, val timestamp: Instant = Instant.now()) : EmbeddingEvent

Emitted after an embedding service call.

GoalAchievedEvent

class GoalAchievedEvent(val agentProcess: AgentProcess, val worldState: WorldState, val goal: Goal) : AbstractAgentProcessEvent

LlmCallFailedEvent

class LlmCallFailedEvent : LlmFailureEvent

The LLM call failed: attempts were exhausted, or the failure was not worth retrying. No LlmResponseEvent will follow. runningTime covers every attempt, as in LlmResponseEvent.

LlmFailureEvent

sealed class LlmFailureEvent : AbstractAgentProcessEvent

An LLM call attempt failed.

LlmInvocationEvent

class LlmInvocationEvent(val agentProcess: AgentProcess, val invocation: LlmInvocation, val interactionId: String) : AbstractAgentProcessEvent

Emitted once per individual LLM invocation (per-call, not per-loop).

LlmRequestEvent

class LlmRequestEvent<O>(val agentProcess: AgentProcess, val action: Action?, val outputClass: Class<O>, val interaction: LlmInteraction, val llmMetadata: <Error class: unknown class>, val messages: List<Message>) : AbstractAgentProcessEvent

LlmResponseEvent

class LlmResponseEvent<O> : AbstractAgentProcessEvent

Response from an LLM

LlmRetryEvent

class LlmRetryEvent : LlmFailureEvent

An attempt failed and another is about to be made. runningTime is that of the failed attempt.

MulticastAgenticEventListener

class MulticastAgenticEventListener(eventListeners: List<AgenticEventListener>) : AgenticEventListener

Multicast event listener that forwards events to multiple listeners. If any listener throws an exception, it is logged but does not stop the processing of other listeners.

ObjectAddedEvent

class ObjectAddedEvent(val agentProcess: AgentProcess, val value: Any) : AbstractAgentProcessEvent, ObjectBindingEvent

Binding to context

ObjectBindingEvent

interface ObjectBindingEvent : AgentProcessEvent

An object was bound to the process. May or may not be found. See subclasses for details.

ObjectBoundEvent

class ObjectBoundEvent(val agentProcess: AgentProcess, val name: String, val value: Any) : AbstractAgentProcessEvent, ObjectBindingEvent

ProcessKilledEvent

class ProcessKilledEvent(val agentProcess: AgentProcess) : AbstractAgentProcessEvent

ProgressUpdateEvent

class ProgressUpdateEvent(val agentProcess: AgentProcess, val name: String, val current: Int, val total: Int) : AbstractAgentProcessEvent

Progress update

RankingChoiceCouldNotBeMadeEvent

class RankingChoiceCouldNotBeMadeEvent<T>(agentPlatform: AgentPlatform, type: Class<T>, val rankings: Rankings<T>, val confidenceCutOff: <Error class: unknown class>, basis: Any, choices: Collection<T>, val timestamp: Instant = Instant.now()) : RankingEvent<T>

RankingChoiceMadeEvent

class RankingChoiceMadeEvent<T>(agentPlatform: AgentPlatform, type: Class<T>, val choice: Ranking<T>, val rankings: Rankings<T>, basis: Any, choices: Collection<T>) : RankingEvent<T>

RankingChoiceRequestEvent

class RankingChoiceRequestEvent<T>(agentPlatform: AgentPlatform, type: Class<T>, basis: Any, choices: Collection<T>) : RankingEvent<T>

RankingEvent

abstract class RankingEvent<T>(val agentPlatform: AgentPlatform, val type: Class<T>, val basis: Any, val choices: Collection<T>) : AgentPlatformEvent

ReplanRequestedEvent

class ReplanRequestedEvent(val agentProcess: AgentProcess, val reason: String) : AbstractAgentProcessEvent

StateTransitionEvent

class StateTransitionEvent(val agentProcess: AgentProcess, val newState: Any, val previousState: Any? = null) : AbstractAgentProcessEvent

The agent process has transitioned to a new state.

ToolCallRequestEvent

class ToolCallRequestEvent(val agentProcess: AgentProcess, val action: Action?, val tool: String, val toolGroupMetadata: ToolGroupMetadata?, val toolInput: String, val llmOptions: <Error class: unknown class>, val correlationId: String = "-") : AbstractAgentProcessEvent

Call to a function from an LLM

ToolCallResponseEvent

class ToolCallResponseEvent : AbstractAgentProcessEvent

Response from a tool call, whether successful or not.

ToolLoopCompletedEvent

class ToolLoopCompletedEvent : AbstractAgentProcessEvent

ToolLoopStartEvent

class ToolLoopStartEvent(val agentProcess: AgentProcess, val action: Action?, val toolNames: List<String>, val maxIterations: Int, val interactionId: String, val outputClass: Class<*>) : AbstractAgentProcessEvent